package com.hliushi.learn.jms;

import com.hliushi.learn.config.ActiveMqConfig;
import org.springframework.jms.annotation.JmsListener;

/**
 * @ClassName QueueConsumer
 * @Description 消息消费者
 * @Author liushi
 * @Date 2021/7/9 9:19
 * @Version V1.0
 **/
// @Service
public class QueueConsumer {

    /**
     * 接受点对点消息
     * #
     * 点对点消息的消费, 只要我们指定目的地即可, jms监听器一直在监听是否有消息过来, 如果有, 则消费
     *
     * @param msg
     */
    @JmsListener(destination = ActiveMqConfig.QUEUE_NAME)
    public void receiveQueueMsg(String msg) {
        System.out.println("收到的消息为: " + msg);
    }
}
